package cn.springboot.linked;

import java.io.IOException;

import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Reducer;

/**
 * @author liufl E-mail:Huberier@allpyra.com
 * @version 创建时间：2017年9月27日 下午4:35:10
 * Reducer阶段，组合出最后的数据输出
 */
public class InvertedIndexReducer  extends Reducer<Text, Text, Text, Text>{

    private Text result = new Text();

    @Override
    protected void reduce(Text key, Iterable<Text> values, Reducer<Text, Text, Text, Text>.Context context)
            throws IOException, InterruptedException {

        //生成文档列表
        String fileList = new String();
        for (Text value : values) {
            fileList += value.toString()+";";
        }
        result.set(fileList);

        context.write(key, result);
    }
}

